package com.sh.data.engine.domain.datadev.flink.model.domain;

import lombok.Data;

import java.util.Date;

@Data
public class FlinkJobDomain {
    /**
     * 主键
     */
    private Long id;

    /**
     * 项目id
     */
    private Long projectId;

    /**
     * 任务节点id
     */
    private Long nodeId;

    /**
     * 对应的是相应的flink task的id
     */
    private Long nodeConfigId;

    /**
     * 0-flink_sql_task,1-flink_task,3-flink_data_sync_task
     */
    private Integer taskType;

    /**
     * 任务状态 1-运行中 2-成功 3-失败 4-停止
     */
    private Integer status;

    private Integer execType;

    /**
     * 计划执行时间
     */
    private Date planTime;

    /**
     * 开始执行时间
     */
    private Date startTime;

    /**
     * 结束执行时间
     */
    private Date endTime;

    /**
     * 会有多个使用"," flink体系中内部使用的id
     */
    private String flinkJobId;

    /**
     * 会有多个使用","
     */
    private String yarnApplicationId;

    /**
     * 创建时间
     */
    private Date createTime;
}
